package com.ynet.middleground.contract.mq;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author liulx
 * @description 生产测试 MQ 专用
 * @date 2020-05-27 14:57
 */
public interface SinkTest {

    String I_CONTRACT_TEST = "i_contract_test";

    /**
     * 合约中心 MQ 测试
     * 
     * @return
     */
    @Input(SinkTest.I_CONTRACT_TEST)
    SubscribableChannel receiveContract();

}
